999c72be0468664c711159cd53deff79e62ee4a1,retrofit-adapters/rxjava/src/test/java/retrofit2/adapter/rxjava/ObservableTest.java,ObservableTest,bodyFailure,#,75

Before Change


    server.enqueue(new MockResponse().setSocketPolicy(DISCONNECT_AFTER_REQUEST));

    BlockingObservable<String> o = service.body().toBlocking();
    try {
      o.first();
      fail();
    } catch (RuntimeException e) {
      assertThat(e.getCause()).isInstanceOf(IOException.class);
    }
  }

After Change


    TestSubscriber<String> subscriber = new TestSubscriber<>();
    service.body().subscribe(subscriber);
    subscriber.assertNoValues();
    subscriber.assertError(IOException.class);
  }

  @Test public void bodyRespectsBackpressure() {